package org.trade.common.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;

public class MessageProcessor implements IMessageProcessor {

	public boolean handleMessage(MessageExt message) {

		System.out.println("用户的获取消息，进行业务处理..." + message.toString());
		
		return true;
	}

}
